package com.aizuda.boot.modules.job;

import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import com.aizuda.boot.modules.system.service.ISysDepartmentService;
import com.aizuda.boot.modules.system.service.ISysUserService;
import com.aizuda.common.toolkit.ThreadLocalUtils;
import com.baomidou.kisso.starter.KissoProperties;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * XxlJob开发示例（Bean模式）
 * <p>
 * 开发步骤：
 * 1、任务开发：在Spring Bean实例中，开发Job方法；
 * 2、注解配置：为Job方法添加注解 "@XxlJob(value="自定义jobhandler名称", init = "JobHandler初始化方法", destroy = "JobHandler销毁方法")"，注解value值对应的是调度中心新建任务的JobHandler属性的值。
 * 3、执行日志：需要通过 "XxlJobHelper.log" 打印执行日志；
 * 4、任务结果：默认任务结果为 "成功" 状态，不需要主动设置；如有诉求，比如设置任务结果为失败，可以通过 "XxlJobHelper.handleFail/handleSuccess" 自主设置任务结果；
 *
 * @author xuxueli 2019-12-11 21:52:51
 */
@Component
@Slf4j
public class FeiShuSyncJob {

    @Autowired
    private KissoProperties properties;

    @Autowired
    private ISysDepartmentService departmentService;

    @Autowired
    private ISysUserService userService;


    /**
     * 1、同步飞书部门和用户
     */
    @XxlJob("feiShuDepSyncJobHandler")
    public void feiShuDepSyncJobHandler() throws Exception {
        XxlJobHelper.log("开始执行飞书同步任务...");
        //获取参数
        String param = XxlJobHelper.getJobParam();
        if (StrUtil.isBlank(param)) {
            XxlJobHelper.log("参数配置失败.格式应为：{\"{}\":\"*****\"}", properties.getConfig().getAccessTokenName());
            XxlJobHelper.handleFail();
            return;
        }


        try {
            JSONObject entries = JSONUtil.parseObj(param);
            String accessToken = entries.getStr(properties.getConfig().getAccessTokenName());
            if (StrUtil.isBlank(accessToken)) {
                XxlJobHelper.log("{}不能为空",properties.getConfig().getAccessTokenName());
                XxlJobHelper.handleFail();
                return;
            }
            //放入当前线程
            ThreadLocalUtils.put(properties.getConfig().getAccessTokenName(), accessToken);
            // 同步部门
            departmentService.syncFeiShuDept();
            // 同步用户
            userService.syncFeiShuUser();
            XxlJobHelper.log("飞书同步任务执行成功");
        } catch (Exception e) {
            XxlJobHelper.handleFail("飞书同步任务执行失败: " + e.getMessage());
            log.error("飞书同步任务执行失败", e);
        } finally {
            ThreadLocalUtils.remove(properties.getConfig().getAccessTokenName());
            XxlJobHelper.log("飞书同步任务执行结束");
        }
    }


    /**
     * 2、同步飞书用户
     * <p>
     * 注意：如果只需要同步用户，可以单独执行此任务
     */
    @XxlJob("feiShuUsersSyncJobHandler")
    public void feiShuUsersSyncJobHandler() throws Exception {
        XxlJobHelper.log("开始执行飞书同步任务...");
        //获取参数
        String param = XxlJobHelper.getJobParam();
        if (StrUtil.isBlank(param)) {
            XxlJobHelper.log("参数配置失败.格式应为：{\"{}\":\"*****\"}", properties.getConfig().getAccessTokenName());
            XxlJobHelper.handleFail();
            return;
        }


        try {
            JSONObject entries = JSONUtil.parseObj(param);
            String accessToken = entries.getStr(properties.getConfig().getAccessTokenName());
            //放入当前线程
            ThreadLocalUtils.put(properties.getConfig().getAccessTokenName(), accessToken);
            // 同步用户
            userService.syncFeiShuUser();
            XxlJobHelper.log("飞书同步任务执行成功");
        } catch (Exception e) {
            XxlJobHelper.handleFail("飞书同步任务执行失败: " + e.getMessage());
            log.error("飞书同步任务执行失败", e);
        } finally {
            ThreadLocalUtils.remove(properties.getConfig().getAccessTokenName());
            XxlJobHelper.log("飞书同步任务执行结束");
        }
    }

    /**
     * 3、同步飞书部门主管
     * <p>
     * 注意：如果只需要同步部门，可以单独执行此任务
     */
    @XxlJob("feiShuDepManagerSyncJobHandler")
    public void feiShuDepManagerSyncJobHandler() throws Exception {
        XxlJobHelper.log("开始执行飞书部门主管同步任务...");
        //获取参数
        String param = XxlJobHelper.getJobParam();
        if (StrUtil.isBlank(param)) {
            XxlJobHelper.log("参数配置失败.格式应为：{\"{}\":\"*****\"}", properties.getConfig().getAccessTokenName());
            XxlJobHelper.handleFail();
            return;
        }

        try {
            JSONObject entries = JSONUtil.parseObj(param);
            String accessToken = entries.getStr(properties.getConfig().getAccessTokenName());
            //放入当前线程
            ThreadLocalUtils.put(properties.getConfig().getAccessTokenName(), accessToken);
            // 同步部门主管
            departmentService.syncFeiShuDepManager();
            XxlJobHelper.log("飞书部门主管同步任务执行成功");
        } catch (Exception e) {
            XxlJobHelper.handleFail("飞书部门主管同步任务执行失败: " + e.getMessage());
            log.error("飞书部门主管同步任务执行失败", e);
        } finally {
            ThreadLocalUtils.remove(properties.getConfig().getAccessTokenName());
            XxlJobHelper.log("飞书部门主管同步任务执行结束");
        }
    }
}
